package cn.hloger.spider.demo.dataxDemo.bean;

import cn.hloger.spider.demo.dataxDemo.annotation.ApiModel;
import lombok.Data;
import lombok.EqualsAndHashCode;
import lombok.experimental.Accessors;


/**
 * <p>
 * 子任务实例表
 * </p>
 *
 * @author pengzhuang
 * @since 2020-09-08
 */
@Data
@Accessors(chain = true)
@EqualsAndHashCode(callSuper = true)
@ApiModel(value = "Zrwsl对象", description = "子任务实例表")
public class Zrwsl extends EntityBeanAgent {

    /**
     *
     */
    private static final long serialVersionUID = 1L;

    /**
     * task id
     */

    @ApiModel(name = "RW_ID", value = "任务id")
    private String rwId;

    /**
     * 任务名称
     */
    @ApiModel(name = "RWMC", value = "任务名称")
    private String rwmc;

    /**
     * 子任务id
     */

    @ApiModel(name = "ZRW_ID", value = "子任务id")
    private String zrwId;

    /**
     * 任务批次号,每个任务每次执行生成一个编号
     */

    @ApiModel(name = "ZRWPCH", value = "任务批次号,每个任务每次执行生成一个编号")
    private String zrwpch;

    /**
     * 子任务json
     */

    @ApiModel(name = "PZ_JSON", value = "子任务json")
    private String pzJson;

    /**
     * 执行结果 -2是就绪 -1是执行中 0是成功 大于0是失败 直接拿得datax的执行结果
     */

    @ApiModel(name = "ZXJG", value = "执行结果 -2是就绪 -1是执行中 0是成功 大于0是失败 直接拿得datax的执行结果")
    private Integer zxjg;

    /**
     * 执行结果8位代码
     */

    @ApiModel(name = "ZXJG_DM", value = "执行结果8位代码")
    private String zxjgDm;

    /**
     * 执行结果说明
     */

    @ApiModel(name = "ZXJG_SM", value = "执行结果说明")
    private String zxjgSm;

    /**
     * 运行日期
     */

    @ApiModel(name = "YXRQ", value = "运行日期")
    private String yxrq;

    /**
     * 开始时间
     */

    @ApiModel(name = "KSSJ", value = "开始时间")
    private String kssj;

    /**
     * 结束时间
     */

    @ApiModel(name = "JSSJ", value = "结束时间")
    private String jssj;

    /**
     * 运行时长(单位S)
     */

    @ApiModel(name = "YXSC", value = "运行时长(单位S)")
    private Integer yxsc;

    /**
     * datax服务器上agent访问地址，包括IP和端口
     */

    @ApiModel(name = "JD_DZ", value = "datax服务器上agent访问地址，包括IP和端口")
    private String jdDz;

    /**
     * 任务类型 1周期任务 2测试任务 3单次任务 4补数据任务
     */

    @ApiModel(name = "RWLX", value = "任务类型 1周期任务-全量 2手动调度 3单次任务 4补数据任务 5周期任务-增量")
    private String rwlx;

    /**
     * 写入成功(记录数)
     */

    @ApiModel(name = "WRITESUCCEEDRECORDS", value = "写入成功(记录数)")
    private Long writeSucceedRecords;

    /**
     * 读取成功(记录数)
     */

    @ApiModel(name = "READSUCCEEDRECORDS", value = "读取成功(记录数)")
    private Long readSucceedRecords;

    /**
     * 最小cpu消耗
     */

    @ApiModel(name = "MINDELTACPU", value = "最小cpu消耗")
    private Long mindeltacpu;

    /**
     * 累计错误数据(byte)
     */

    @ApiModel(name = "TOTALERRORBYTES", value = "累计错误数据(byte)")
    private Long totalerrorbytes;

    /**
     * 写入成功(byte)
     */

    @ApiModel(name = "WRITESUCCEEDBYTES", value = "写入成功(byte)")
    private Long writesucceedbytes;

    /**
     * 当前cpu消耗
     */

    @ApiModel(name = "CURDELTACPU", value = "当前cpu消耗")
    private Long curdeltacpu;

    /**
     * 传输速度(byte)
     */

    @ApiModel(name = "BYTESPEED", value = "传输速度(byte)")
    private Long bytespeed;

    /**
     * 最大使用内存(byte)
     */

    @ApiModel(name = "MSMAXUSEDSIZE", value = "最大使用内存(byte)")
    private Long msmaxusedsize;

    /**
     * 累计错误(记录数)
     */

    @ApiModel(name = "TOTALERRORRECORDS", value = "累计错误(记录数)")
    private Long totalErrorRecords;

    /**
     * 传输速度(记录数)
     */

    @ApiModel(name = "RECORDSPEED", value = "传输速度(记录数)")
    private Long recordspeed;

    /**
     * reader等待时间(微秒 /1000的3次方=秒)
     */

    @ApiModel(name = "WAITREADERTIME", value = "reader等待时间(微秒 /1000的3次方=秒)")
    private Long waitreadertime;

    /**
     * 写入成功(字节  单表是整体速度即=writeSucceedBytes 多表跟task相关 1个表/表分区对应1个task 这里就是多task总和)
     */

    @ApiModel(name = "WRITERECEIVEDBYTES",
            value = "写入成功(字节  单表是整体速度即=writeSucceedBytes 多表跟task相关 1个表/表分区对应1个task 这里就是多task总和)")
    private Long writeReceivedBytes;

    /**
     * write等待时间(微秒 /1000的3次方=秒)
     */

    @ApiModel(name = "WAITWRITERTIME", value = "write等待时间(微秒 /1000的3次方=秒)")
    private Long waitwritertime;

    /**
     * cpu平均消耗
     */

    @ApiModel(name = "AVERAGECPU", value = "cpu平均消耗              ")
    private Long averagecpu;

    /**
     * 当前task读取成功(记录数)
     */

    @ApiModel(name = "TOTALREADRECORDS", value = "当前task读取成功(记录数)")
    private Long totalreadrecords;

    /**
     * 写入成功(记录数  单表是整体速度即=writeSucceedRecords 多表跟task相关 1个表/表分区对应1个task 这里就是多task总和)
     */

    @ApiModel(name = "WRITERECEIVEDRECORDS", value = "写入成功(记录数  单表是整体速度即=writeSucceedRecords " +
            "多表跟task相关 1个表/表分区对应1个task 这里就是多task总和)")
    private Long writereceivedrecords;

    /**
     * 读取成功(byte 暂不明确  加入多表测试后再观察)
     */

    @ApiModel(name = "READSUCCEEDBYTES", value = "读取成功(byte 暂不明确  加入多表测试后再观察)")
    private Long readsucceedbytes;

    /**
     * 最大cpu消耗
     */

    @ApiModel(name = "MAXDELTACPU", value = "最大cpu消耗")
    private Long maxdeltacpu;

    /**
     * 读取成功(byte 暂不明确  加入多表测试后再观察)
     */

    @ApiModel(name = "TOTALREADBYTES", value = "读取成功(byte 暂不明确  加入多表测试后再观察)")
    private Long totalreadbytes;

    /**
     * 瞬时内存使用(byte)
     */

    @ApiModel(name = "MSUSEDSIZE", value = "瞬时内存使用(byte)")
    private Long msusedsize;

    /**
     * 上报ip4地址
     */

    @ApiModel(name = "IP4", value = "上报ip4地址")
    private String ip4;

    /**
     * 上报时间
     */

    @ApiModel(name = "CREATETIME", value = "上报时间")
    private Long createtime;

    /**
     * 创建人名称
     */

    @ApiModel(name = "CJR_MC", value = "创建人名称")
    private String cjrMc;

    /**
     * 接口类别(1.updateZrwsl 2.updatecallback 3.updateJkzb记录datax任务成功失败总数，结果预览从es读消息这个其实不重要
     * 4.createDataxRwzxYcxx保存异常数据)
     */
    @ApiModel(name = "jklb", value = "接口类别")
    private Integer jklb;

    /**
     * 对应短的任务id，用于任务启动
     */
    @ApiModel(name = "jobId", value = "对应短的任务id，用于任务启动")
    private String jobId;

    @ApiModel(name = "rwlyDm", value = "任务来源代码（集成01  标签02  离线03  共享04 脱敏05 数据质量06）")
    private String rwlyDm;

    @ApiModel(name = "engineMode", value = "引擎类型  datax | flinkx")
    private String engineMode;

    @ApiModel(name = "sfxp", value = "是否续跑 Y | N ")
    private String sfxp;

    @ApiModel(name = "xpPch", value = "续跑的上一个实例批次号 ")
    private String xpPch;

    @ApiModel(name = "taskType", value = "任务类型 Local yarn")
    private String taskType;


}
